package org.example.bio;


import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;


//阻塞io服务端
public class BioServer {

    public static void main(String[] args) throws IOException {
        ServerSocket socket = new ServerSocket(8081);

        while(true){
            Socket accept = socket.accept();
            InputStream inputStream = accept.getInputStream();
            //读取输入流
            byte[] bytes = new byte[1024];
            int length;
            // 没读完就一直读 会等待  做不了其他事情 主要是因为  同一时间 线程与流绑定了 一次要等完一个流  需要一种机制 不在一个流上等
            while ((length = inputStream.read(bytes)) != -1) {
                System.out.println(new String(bytes,0,length));
            }
            System.out.println("客户端断开链接");
            inputStream.close();
        }


    }
}
